package tc.alert.tckejisoc.task;


import com.alibaba.fastjson.JSON;
import com.fasterxml.jackson.databind.util.BeanUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.beanutils.BeanUtils;
import org.apache.commons.lang3.StringUtils;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.RangeQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;
import tc.alert.tckejisoc.cache.CacheData;
import tc.alert.tckejisoc.domain.SocBanned;
import tc.alert.tckejisoc.domain.SocIp;
import tc.alert.tckejisoc.dto.Constants;
import tc.alert.tckejisoc.dto.EdrDTO;
import tc.alert.tckejisoc.kafka.service.KafkaProducerService;
import tc.alert.tckejisoc.service.GeoIPService;
import tc.alert.tckejisoc.service.SocBannedService;
import tc.alert.tckejisoc.service.SocIpService;
import tc.alert.tckejisoc.service.UserInfoService;
import tc.alert.tckejisoc.utils.DateUtils;
import tc.alert.tckejisoc.utils.EsUtils;

import java.io.IOException;
import java.time.Instant;
import java.util.*;

@Component
@Slf4j
public class WxSmsTask {


    @Scheduled(fixedRate = 3000)
    public Object test(){
//        String url = "http//192.168.11.2:9200" + "/";
//        ResponseEntity<Map> response = esRestTemplate.getForEntity(url, Map.class);
//        return response.getBody();
        log.debug("12312312312asd阿三大苏打实打实大苏打实打实3123123123");
        return null;
    }


//
}
